c5f7e229cb34a3cda7395670722da1329cf95b3e,src/main/java/net/hasor/rsf/center/server/manager/ServiceManager.java,ServiceManager,requestProviders,#InterAddress#String#String#,488
Before Change
/** 请求Center�一次全�推� */
public Result<Boolean> requestProviders(InterAddress rsfAddress, String registerID, String serviceID) {
// .é‡?新计算ObjectID,å¹¶ä¸”æ ¡éªŒregisterID有效性。
Result<String> objectIDResult = this.checkAndEvalObjectID(rsfAddress, registerID, serviceID);
String oriObjectKey = null;
if (!objectIDResult.isSuccess()) {
ResultDO<Boolean> result = new ResultDO<Boolean>();
result.setSuccess(false);
result.setResult(false);
result.setErrorInfo(objectIDResult.getErrorInfo());
return result;
} else {
oriObjectKey = objectIDResult.getResult();
}
//
// .刷新更新时间
After Change
//
// .检查registerID是�为订阅者
Result<ObjectDO> consumerResult = this.dataAdapter.queryObjectByID(registerID);
if (consumerResult == null || !consumerResult.isSuccess() || consumerResult.getResult() == null) {
return buildFailedResult(consumerResult);
}
if (!StringUtils.equals(RsfCenterConstants.Center_DataKey_Consumer, consumerResult.getResult().getType())) {
ResultDO<Boolean> result = new ResultDO<Boolean>();
result.setErrorInfo(ErrorCode.ServiceTypeFailed_Error);
result.setSuccess(false);
return result;
}